批量操作 |
您所在的位置：网站首页 › mybatisplus 动态数据源 批量更新 慢 › 批量操作 |
|
# 批量操作 3.5.4 + 版本支持 事务需要手动自行控制(默认false) 注意 autoCommit参数在Spring项目下是无效的,具体见SpringManagedTransactionFactory,在原生mybatis下可用 执行返回值为批量处理结果,业务可根据返回值判断是否成功 数据能否写入或更新取决于代码能否正确执行到flushStatements 支持Spring与非Spring项目使用 执行抛出异常为PersistenceException saveOrUpdate是个比较有争议的方法,个人建议批量操作保持为简单的新增或更新操作 # 类说明 # MybatisBatch 泛型为具体 实际数据类型 sqlSessionFactory可通过容器获取,非Spring容器下可在自行初始化Mybatis时将上下文记录起来 dataList为实际的批量数据处理 (非空) # MybatisBatch.Method实际为BatchMethod, 封装了框架内部操作方法简化调用. 泛型为 实际Mapper方法参数需要的类型 mapperClass为具体的实际Mapper类 # BatchMethod 泛型为 实际Mapper方法参数需要的类型 statementId : 执行的MappedStatement parameterConvert: 参数类型转换处理器,当数据类型与实际mapper方法参数不一致时,可以通过类型转换器进行转换 # 使用说明 构建MybatisBatch (将数据与sqlSessionFactory绑定起来) 构建MybatisBatch.Method (确定执行执行Mapper类方法) 执行操作 (执行处理操作,将批量参数转换为实际mapper需要的参数) # 返回值说明List 执行返回每次按照执行MappedStatement + sql分组返回的操作结果 注意 例如批量根据id更新: 假设10条数据, 5条更新一个字段 5条更新两个字段 , 那返回值就是容量为2的List, 里面各存储了五条记录更新情况 update table set c1 = ? where id = ? //只更新一个字段 update table set c1 = ? , c2 = ? where id = ? // 只更新两个字段 mappedStatement: 执行的MappedStatement sql: 执行sql parameterObjects: 参数列表 updateCounts[]: 影响行数(与上面的parameterObjects数据一一对应) # 使用示例框架提供了一个MybatisBatchUtils进行静态方法调用. # execute适用于insert,update,delete操作 # 示例一: 数据类型为实体 List userList = Arrays.asList(new H2User(2000L, "测试"), new H2User(2001L, "测试")); MybatisBatch mybatisBatch = new MybatisBatch(sqlSessionFactory, userList); MybatisBatch.Method method = new MybatisBatch.Method(H2UserMapper.class); mybatisBatch.execute(method.insert()); 1234# 示例二: 数据类型为非实体 List ids = Arrays.asList(120000L, 120001L); MybatisBatch mybatisBatch = new MybatisBatch(sqlSessionFactory, ids); MybatisBatch.Method method = new MybatisBatch.Method(H2UserMapper.class); mybatisBatch.execute(method.insert(id -> { // 将id转换为实体 H2User h2User = new H2User(); h2User.setTestId(id); return h2User; })); 123456789# 示例三: 自定义方法插入(无注解) // mapper方法(方法参数无注解) @Insert( "insert into h2user(name,version) values( #{name}, #{version})" ) int myInsertWithoutParam(H2User user1); // 准备数据集合 List h2UserList = new ArrayList(); for (int i = 0; i { MybatisBatch.Method mapperMethod = new MybatisBatch.Method(H2UserMapper.class); // 执行批量插入 MybatisBatchUtils.execute(sqlSessionFactory, h2UserList, mapperMethod.insert()); throw new RuntimeException("出错了"); }); 123456789 |
今日新闻 |
推荐新闻 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |